012966685a7fbb4e6c4a1c049b6d6ac6b940fdf5,staging/maven-plugin/src/main/java/org/sonatype/nexus/maven/staging/deploy/strategy/AbstractStagingDeployStrategy.java,AbstractStagingDeployStrategy,initRemoting,#MavenSession#StagingParameters#,80

Before Change


        StagingWorkflowV2Service service = remoting.getStagingWorkflowV2Service();
        //service.setProgressTimeoutMinutes();
        //service.setProgressPauseDurationSeconds();
        service.setProgressMonitor(new ProgressMonitor()
        {
            private boolean needsNewline;

            private void maybePrintln() {
                if (needsNewline) {
                    System.out.println();
                    needsNewline = false;
                }
            }

            @Override
            public void start() {
                getLogger().debug("START");
            }

            @Override
            public void tick() {
                if (getLogger().isDebugEnabled()) {
                    getLogger().debug("TICK");
                }
                else {
                    needsNewline = true;
                    System.out.print(".");
                }
            }

            @Override
            public void pause() {
                getLogger().debug("PAUSE");
            }

            @Override
            public void info(String message) {
                maybePrintln();
                getLogger().info(" * " + message);
            }

            @Override
            public void error(String message) {
                maybePrintln();
                getLogger().error(" * " + message);
            }

            @Override
            public void stop() {
                maybePrintln();
                getLogger().debug("STOP");
            }

            @Override
            public void timeout() {
                maybePrintln();
                getLogger().warn("TIMEOUT");
            }

            @Override
            public void interrupted() {
                maybePrintln();
                getLogger().warn("INTERRUPTED");
            }
        });
    }

    protected synchronized Remoting getRemoting()

After Change



        // install and configure progress monitor
        StagingWorkflowV2Service service = remoting.getStagingWorkflowV2Service();
        service.setProgressMonitor(new ProgressMonitorImpl(getLogger()) {
            @Override
            public void info(final String message) {
                super.info(" * " + message);
            }

            @Override
            public void error(final String message) {
                super.error(" * " + message);
            }
        });

        // TODO: Configure these bits
        //service.setProgressTimeoutMinutes();